package com.szh.consumer.lister;


import com.szh.consumer.mq.MessageMq;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * V2
 * 这种方式使用，已经从3.1 版本开始，过时了
 * 新版本使用 例子：https://blog.csdn.net/whiteForever/article/details/125244512
 */
@Slf4j
@EnableBinding({MessageMq.class})
public class V2Lister {
    
    // headers['type'] 中的type，类似 路由key，要唯一。
    @StreamListener(value = MessageMq.INPUT,condition = "headers['type']=='modifyOrg'")
    // 入参，要和，生产者，中的一致。
    public void orgUpdate(String payload) {
        log.info("ServiceMqReceiver orgUpdate {}",payload);
    }
}

